package org.kth.dks.test_bed;

import org.kth.dks.dks_comm.ConnectionManager;

class Simulator_Node
    extends Thread {
  ConnectionManager cm = null;

  public Simulator_Node(ConnectionManager newcm) {
    cm = newcm;
    this.setName(Simulator_Node.class.getName());
    this.start();
  }

  public void run() {
    while (true) {
//      CommBufferInElement buff = cm.receive();
      //DKSPrint.Println( "New MSG from DKS node " + buff.GetDKSRef().GetID() + ",MSG: " + buff.GetMsg().GetData() );
      //DKSPrint.Println( "New MSG from DKS node " + buff.GetDKSRef().GetID() );
    }
  }
}
